package cn.itsnkkka.consumer;

import com.rabbitmq.client.Channel;

/**
 * @author xuezipeng
 * @date 2023-04-23 12:47
 */
public interface IConsumer {

    // TODO QOS和线程数建议写配置文件，这样只是为了方便

    Integer QOS = 500;

    Integer THREAD_COUNT = 30;

    public void process(byte[] body, Channel channel);

}
